package cn.jingyinghui.testreactor;

import reactor.core.publisher.Flux;

public class ReactorHelloWorld {

    public static void main(String[] args) {
        // ============= 1. 创建发布者（数据源） =============
        Flux<String> publisher = Flux.just("Hello", "Reactor", "World!");

        // ============= 2. 创建订阅者（消费者） =============
        publisher.subscribe(
                // 收到数据时的处理（onNext）
                data -> System.out.println("接收数据: " + data),

                // 错误处理（onError）
                error -> System.err.println("发生错误: " + error),

                // 完成处理（onComplete）
                () -> System.out.println("流处理完成!")
        );
    }
}
